package com.gallop.mq.core;

/**
 * MQ 消息监听拦截器
 */
public interface MQListenerInterceptor {

    default void beforeInvoke(Object message) {

    }

    default void afterInvoke(Object message, Object result) {

    }

    default void onError(Object message, Exception exception) {

    }
}
